package com.mkz.producer.feign;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestParam;

import com.mkz.core.common.constant.ServiceNameConstants;
import com.mkz.core.common.util.ResponseResult;
import com.mkz.producer.feign.factory.ProducerServiceFallbackFactory;

import io.swagger.annotations.ApiOperation;

/**
 * ClassName: ProducerService 
 * @Description: Kafka消息发送
 * @author: KuangJianyu
 * @date: 2020年4月16日
 */
@FeignClient(contextId = "producerService", value = ServiceNameConstants.MSMQ_SERVICE, fallbackFactory = ProducerServiceFallbackFactory.class)
public interface ProducerClient {
	/**
	 * @Description: 普通消息发送
	 * @param topic 主题
	 * @param content 消息内容
	 * @param bustype 业务类别
	 * @return
	 * @author: KuangJianyu
	 * @date: 2020年4月16日
	 */
	@ApiOperation(value = "普通消息发送", notes = "普通消息")
	@PutMapping("/basicSend")
	public ResponseResult<Boolean> basicSend(@RequestParam String topic, @RequestParam String content, @RequestParam String bustype);
}
